package com.ctsi.ftp.server;

public class UserLoggerThread extends Thread {
	private String hdfsRootPath;
	
	private String remoteRootPath;

	private String filePostfix;
	
	public UserLoggerService userLoggerService;
	
	//*******************
	public int threadNum;

	public UserLoggerThread(UserLoggerService userLoggerService, String hdfsPath, String remotePath, String filePostfix, int threadNum) {
		this.hdfsRootPath = hdfsPath;
		this.remoteRootPath = remotePath;
		this.filePostfix = filePostfix;
		this.setName("ResourceService:UserLoggerService");
		this.userLoggerService = userLoggerService;
		this.threadNum=threadNum;
	}

	public void run() {
		try {
			userLoggerService.send(hdfsRootPath, remoteRootPath,filePostfix,threadNum);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}
